package com.hefei.garden.service;

import com.hefei.garden.pojo.KafkaBaseDto;

import java.util.List;

/**
 * @author: devil
 * @Date: 2022/8/21 16
 * @Description:
 */
public interface KafkaConsumerService {

    List<Integer> getKafkaTopicPartition(KafkaBaseDto kafkaBaseDto);

    String startKafkaDataPull(KafkaBaseDto kafkaBaseDto);

    String stopKafkaDataPull(KafkaBaseDto kafkaBaseDto);
}
